package rddSummary.transition.key_value_type

import org.apache.spark.{SparkConf, SparkContext}

object test_join {
  def main(args: Array[String]): Unit = {

    val conf = new SparkConf().setAppName("test").setMaster("local")
    val sparkContext = new SparkContext(conf)

    /**
     * 在类型为(K,V)和(K,W)的RDD上调用，返回一个相同 key 对应的所有元素连接在一起的(K,(V,W))的RDD
     */

    val dataRDD1 = sparkContext.makeRDD(List((1, "zahngsan"), (2, "lisi"), (3, "wangwu")))
    val dataRDD2 = sparkContext.makeRDD(List((1, "张三"), (2, "李四"), (3, "王五")))

    val value1 = dataRDD1.join(dataRDD2)
    val value2 = dataRDD2.join(dataRDD1)

    value1.collect().foreach(println)
    value2.collect().foreach(println)

    sparkContext.stop()
  }

}
